package com.itsu.integration.demo;

import org.springframework.messaging.Message;
import org.springframework.messaging.support.MessageBuilder;

//@Component
public class GetJsonEndpoint {
	
	public Message<?> getJson(final Message<?> inMessage) {
		// 传入内容为以下形式可以获取Json内容。
		// http://127.0.0.1:8081/receiveGateway2?json=%7B%22key%22%3A%20123,%22key1%22%3A%20%22anc%22%7D
		// 后续可以在这里做filter
		System.out.println("xXXXXXXXXXXXXXXXXXXXXXXXXXXGetJsonEndpoint.getJson " + inMessage.getPayload().toString()
				+ " XXXXXXXXXXXXX");

		String recvedJsonStr = inMessage.getPayload().toString();

		// Todo HardCode，需要根據前端傳輸内容的不同進行處理。
		recvedJsonStr = recvedJsonStr.substring(recvedJsonStr.indexOf("{json=[") + "{json=[".length(),
				recvedJsonStr.indexOf("]}"));

		// System.out.println("xXXXXXXXXXXXXXXXXXXXXXXXXXXFirstEndpoint.get "
		// +recvedJsonStr+ " XXXXXXXXXXXXX");

		final Message<?> message = MessageBuilder.withPayload(recvedJsonStr).build();
		return message;
	}
}
